package cn.sgy.disruptor.dsl;


import cn.sgy.disruptor.Sequence;
import cn.sgy.disruptor.SequenceBarrier;

import java.util.concurrent.ThreadFactory;

interface ConsumerInfo {
    Sequence[] getSequences();

    SequenceBarrier getBarrier();

    boolean isEndOfChain();

    void start(ThreadFactory threadFactory);

    void halt();

    void markAsUsedInBarrier();

    boolean isRunning();
}
